getUnreadMessagesFlowInternal

open fun getUnreadMessagesFlowInternal(currentTimestamp: String): Flow<List<MessageEntity>>